package xyz.hubery.stream;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.MessageChannel;


/**
 * 消息通道接口
 */
public interface Sink {

    /**
     * 接收创建订单的消息
     * @return
     */
    @Input("order-in")
    MessageChannel orderInChannel() ;

    /**
     * 接收撤销订单的消息
     */
    @Input("rem-order-in")
    MessageChannel remOrderInChannel();


}
